package com.reload.stream;

import java.util.stream.Stream;

/**
 * @Date: 2024/12/3 16:51
 * @Author: jianchenlong
 * @Description: 流是否是并发的
 */
public class StreamThread {
    public static void main(String[] args) {
        // 注意：当启用并发的时候，需要自行处理线程安全问题。流的所有操作都是无状态数据，数据状态仅在当前函数内有效不溢出函数外。
        System.out.println("main线程 = " + Thread.currentThread().getName());
        long count = Stream.of(1, 2, 3, 4, 5)
                .filter(item -> {
                    System.out.println("filter线程 = " + Thread.currentThread().getName());
                    return true;
                })
                .parallel()
                .count();
    }
}
